package com.mgm.kafka.service;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface KafkaConsumerService {
	
	void onMessage(ConsumerRecord<String, String> record);
}
